// http.ts
import axios from "axios";
import type { AxiosRequestConfig, AxiosResponse } from "axios";
import { TIME_OUT } from "./config";
import qs from "qs";
import { ElMessage } from "element-plus";
import {
  getCustomLocalStorage,
  removeLocalStorage
} from '@/utils/localStorage';


// 路由
import router from '@/router';


// 声明一个 Map 用于存储每个请求的标识 和 取消函数
const pending = new Map()
/**
 * 添加请求
 * @param {Object} config 
 */
const addPending = (config: AxiosRequestConfig) => {
  const url = [
    config.method,
    config.url,
    qs.stringify(config.params),
    qs.stringify(config.data)
  ].join('&')
  config.cancelToken = config.cancelToken || new axios.CancelToken(cancel => {
    if (!pending.has(url)) { // 如果 pending 中不存在当前请求，则添加进去
      pending.set(url, cancel)
    }
  })
}
/**
 * 移除请求
 * @param {Object} config 
 */
const removePending = (config: AxiosRequestConfig) => {
  const url = [
    config.method,
    config.url,
    qs.stringify(config.params),
    qs.stringify(config.data)
  ].join('&')
  if (pending.has(url)) { // 如果在 pending 中存在当前请求标识，需要取消当前请求，并且移除
    const cancel = pending.get(url)
    cancel(url)
    pending.delete(url)
  }
}

/**
 * 清空 pending 中的请求（在路由跳转时调用）
 */
export const clearPending = () => {
  for (const [url, cancel] of pending) {
    cancel(url)
  }
  pending.clear()
}

const showStatus = (response) => {
  switch (response.code) {
    case 403:
      ElMessage.error('拒绝访问(403)');
      router.push('/403');
      break
    case 404:
      ElMessage.error('请求出错(404)');
      router.push('/404');
      break
    case 500:
      ElMessage.error('服务器错误(500)');
      router.push('/500');
      break
    case 1001:
      console.log(1)
      ElMessage.error(response.message);
      removeLocalStorage('token');
      removeLocalStorage('userInfo');
      router.push('/login');
      break
    default:
      ElMessage.error(response.message);
  }
}

const service = axios.create({
  // 联调
  // baseURL: 'http://hxbfb.bailingkeji.com', // 'http://hxbfb.bailingkeji.com', // 域名配置，可添加变量配置文件定义,
  // 是否跨站点访问控制请求
  withCredentials: false,
  timeout: TIME_OUT,
  validateStatus() {
    // 使用async-await，处理reject情况较为繁琐，所以全部返回resolve，在业务代码中处理异常
    return true
  },
})

// 请求拦截器
service.interceptors.request.use((config: AxiosRequestConfig) => {
  removePending(config) // 在请求开始前，对之前的请求做检查取消操作
  addPending(config) // 将当前请求添加到 pending 中
  // 获取token，并将其添加至请求头中
  if (getCustomLocalStorage('token')) {

    config.headers['token'] = getCustomLocalStorage('token');
  }
  return config
}, (error) => {
  // 错误抛到业务代码
  error.data = {}
  error.data.msg = '服务器异常，请联系管理员！'
  return Promise.resolve(error)
})

// 响应拦截器
service.interceptors.response.use((response: AxiosResponse) => {
  removePending(response) // 在请求结束后，移除本次请求
  /**
   * response.data.code:
   * 200 请求成功
   * 1020 "账号或者密码错误"
  */
  const includesArr = [200, 1020, 0, 1, 2, 3, 4];
  if (includesArr.includes(Number(response.data.code))) {
    return response;
  };
  // 处理http错误，抛到业务代码
  showStatus(response.data);
}, (error) => {
  if (axios.isCancel(error)) {
    console.log('repeated request: ' + error.message)
  } else {
    // handle error code
    // 错误抛到业务代码
    error.data = {}
    error.data.msg = '请求超时或服务器异常，请检查网络或联系管理员！'
    error.data.code = '500'
    ElMessage.error(error)
  }
  return Promise.reject({ data: {} })
})

export default service
